package com.example.demo.server.impl;

import com.example.demo.dao.UserMessageRepository;
import com.example.demo.pojo.Usermessage;
import com.example.demo.server.UserMessageServer;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.util.List;

/**
 * @author 刘二朋
 * @date 2020-12-05 17:10
 */
@Service
public class UserMessageServerImpl implements UserMessageServer {

    @Resource
    UserMessageRepository userMessageRepository;


    /**
     * 保存一条 消息 , 到数据库
     *
     * @param from    消息的发送者
     * @param to      消息的接受者
     * @param type    消息的类型
     * @param time    消息的时间
     * @param context 消息的内容
     * @return
     */
    @Override
    public Usermessage addUserMessage(String converid,String from, String to, String type, String time, String context) {
//        创建一个消息对象
        Usermessage usermessage = new Usermessage();
        usermessage.setConverid(converid);
        usermessage.setMessagefrom(from);
        usermessage.setMessageto(to);
        usermessage.setMessagetype(type);
        usermessage.setMessagetime(time);
        usermessage.setMessagecontent(context);
        return userMessageRepository.save(usermessage);
    }

    /**
     * 通过消息的所属会话的id , 来进行查询用户 , 把消息封装成一个容器  ,返回到客户端,  ,进行展示
     *
     * @param converid 要进行处理的消息的id
     * @return 返回查询到的消息
     */
    @Override
    public List<Usermessage> selectUserMessage(String converid) {
        return userMessageRepository.selectUserMessage(converid);
    }
}
